package com.hzit.rocketmq.listener;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

/**
 * 类名：
 * 作者：WF
 * 功能：
 */
@RocketMQMessageListener(topic = "topic-01",consumerGroup = "consumer-01")
@Component
public class MyRocketMQListener implements RocketMQListener<String> {

	@Override
	public void onMessage(String message) {
		System.out.println("获取到消息:" + message);
	}
}
